package com.gitee.source

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment,_}
/*
  也是和DataAPI一样
 */
object SourceFileTest {
  def main(args: Array[String]): Unit = {
    val senv: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    val data: DataStream[String] = senv.readTextFile("file:///D:\\data\\input\\a.txt")
    data.print()
    senv.execute()
  }

}
